package com.xian;

import java.io.File;
import java.util.Scanner;

public class MyTest {
    public static void main(String[] args) throws Exception {
        System.out.println("Hello Spark !");

        Scanner scanner = new Scanner(new File("data/my.sql"));
        String sql = null;
        while (scanner.hasNext()) {
            sql  = scanner.nextLine();
            System.out.println("执行SQL:"+sql);
        }

    }
}
